package org.example.flinkderivedvariableengine.service;

import org.example.flinkderivedvariableengine.job.FlinkProcessDerivedVariableJob;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @author ：zhshi
 * @date ：Created in 17:27 2025/2/27
 * @description：
 */
@Service
public class FlinkJobService {
    private FlinkProcessDerivedVariableJob flinkProcessDerivedVariableJob;

    public void runFlinkJob() throws Exception {
        flinkProcessDerivedVariableJob.main(new String[]{});
    }
}
